/**
 * Copyright (c) 2013-2022 Nikita Koksharov
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.redisson.client.codec;

import java.io.IOException;

import org.redisson.client.handler.State;
import org.redisson.client.protocol.Decoder;
import org.redisson.client.protocol.Encoder;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;

/**
 * ByteArrayCodec类继承自BaseCodec，提供了一种对字节数组进行编码和解码的实现。
 * 该类实现了将字节数组与ByteBuf之间的转换，适用于在Netty等框架中进行数据传输。
 */
public class ByteArrayCodec extends BaseCodec {

    /**
     * 单例实例，用于获取ByteArrayCodec的实例，避免多次实例化。
     */
    public static final ByteArrayCodec INSTANCE = new ByteArrayCodec();

    /**
     * Encoder实例，用于对字节数组进行编码。
     * 通过实现Encoder接口，将字节数组转换为ByteBuf。
     */
    private final Encoder encoder = new Encoder() {
        @Override
        public ByteBuf encode(Object in) throws IOException {
            // 将字节数组包装为ByteBuf，以便进行网络传输
            return Unpooled.wrappedBuffer((byte[]) in);
        }
    };

    /**
     * Decoder实例，用于对字节数组进行解码。
     * 通过实现Decoder接口，将ByteBuf转换为字节数组。
     */
    private final Decoder<Object> decoder = new Decoder<Object>() {
        @Override
        public Object decode(ByteBuf buf, State state) {
            // 根据ByteBuf可读字节长度创建字节数组
            byte[] result = new byte[buf.readableBytes()];
            // 从ByteBuf中读取字节到字节数组
            buf.readBytes(result);
            // 返回解码后的字节数组
            return result;
        }
    };

    /**
     * 获取解码器实例。
     * @return 返回解码器对象，用于将ByteBuf解码为字节数组。
     */
    @Override
    public Decoder<Object> getValueDecoder() {
        return decoder;
    }

    /**
     * 获取编码器实例。
     * @return 返回编码器对象，用于将字节数组编码为ByteBuf。
     */
    @Override
    public Encoder getValueEncoder() {
        return encoder;
    }

}
